26f9d2395171d5a75091a8d45f101c1c449177f3,src/main/java/com/aol/cyclops2/internal/stream/ReactiveStreamX.java,ReactiveStreamX,subscribeAll,#Consumer#,577
Before Change
@Override
public void subscribeAll(final Consumer<? super T> action) {
source.subscribeAll(action, this.defaultErrorHandler,()->{});
}
After Change
@Override
public void subscribeAll(final Consumer<? super T> action) {
if(async==Type.NO_BACKPRESSURE)
source.subscribeAll(action, this.defaultErrorHandler,()->{});
else
source.subscribe(action, this.defaultErrorHandler,()->{}).request(Long.MAX_VALUE);
}